package com.whz.mlc.queue;

import com.whz.generic.memqueue.MessageConsumer;
import com.whz.generic.memqueue.MessageSender;

/**
 * 简单队列
 *
 * @author whz
 */
public interface SimpleQueue extends MessageSender {
    /**
     * 添加消费者
     *
     * @param consumer 消息消费者
     */
    void addConsumer(MessageConsumer consumer);
}